f14914d467829362a483e62e493e7a9b1ac919be,src/main/java/bazahe/httpproxy/ConnectProxyHandler.java,ConnectProxyHandler,handle,#Socket#Socket#String#String#HttpMessageListener#,100
Before Change
private void handle(Socket serverSocket, Socket clientSocket, String protocol, String target,
@Nullable HttpMessageListener httpMessageListener) throws IOException {
HttpInputStream srcInput = new HttpInputStream(new BufferedInputStream(serverSocket.getInputStream()));
HttpOutputStream srcOutput = new HttpOutputStream(serverSocket.getOutputStream());
HttpInputStream destInput = new HttpInputStream(new BufferedInputStream(clientSocket.getInputStream()));
HttpOutputStream destOutput = new HttpOutputStream(clientSocket.getOutputStream());
while (true) {
After Change
HttpInputStream srcInput = new HttpInputStream(new BufferedInputStream(
new ObservableInputStream(serverSocket.getInputStream(), clientSocket.getOutputStream())));
HttpInputStream destInput = new HttpInputStream(new BufferedInputStream(
new ObservableInputStream(clientSocket.getInputStream(), serverSocket.getOutputStream())));
while (true) {